package rddSummary.transition.key_value_type

import org.apache.spark.{SparkConf, SparkContext}

object test_sortByKey {
  def main(args: Array[String]): Unit = {

    val conf = new SparkConf().setAppName("test").setMaster("local")
    val sparkContext = new SparkContext(conf)

    /**
     * 在一个(K,V)的RDD上调用，K必须实现Ordered 接口(特质)，返回一个按照 key 进行排序的
     */
    val dataRDD = sparkContext.makeRDD(List((1, "zahngsan"), (2, "lisi"), (3, "wangwu")))

    val value1 = dataRDD.sortByKey(true) //默认值：true
    val value2 = dataRDD.sortByKey(false)

    value1.collect().foreach(println)
    value2.collect().foreach(println)

    sparkContext.stop()
  }

}
